package com.example.socket.longlink;

import java.util.concurrent.ArrayBlockingQueue;

/**
 * @author hej   暂时用本地队列测试，以后转用kafka或mq
 * @date 2024/9/12 19:06
 */
public class QueueHolder {
    private static final ArrayBlockingQueue<LockFeed> queue = new ArrayBlockingQueue<>(100);

    public static ArrayBlockingQueue<LockFeed> get() {
        return queue;
    }

    public static void put(LockFeed feed) {
        try {
            queue.put(feed);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
